ConcurrentSignalAsync class¶
Defined in
Namespace: ReactiveUI.Primitives.Async.Signals
Assembly: ReactiveUI.Primitives.Async.Core.dll
Full name: ReactiveUI.Primitives.Async.Signals.ConcurrentSignalAsync<T>
Modifiers: public sealed
Summary¶
Provides an asynchronous Signal that forwards notifications to observers concurrently.
Applies to
net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481, net471
Class hierarchy
classDiagram
class ConcurrentSignalAsync~T~
class ISignalAsync~T~ {
<>
}
ISignalAsync~T~ <|.. ConcurrentSignalAsync~T~
class IObserverAsync~T~ {
<>
}
IObserverAsync~T~ <|.. ConcurrentSignalAsync~T~
class IAsyncDisposable {
<>
}
IAsyncDisposable <|.. ConcurrentSignalAsync~T~
class IObservableAsync~T~ {
<>
}
IObservableAsync~T~ <|.. ConcurrentSignalAsync~T~
Implements: ISignalAsync
Remarks¶
Observers are notified in parallel for each event. This class is suitable for scenarios where high throughput and concurrent notification of multiple observers are required. Thread safety is ensured for observer notification operations. Cancellation tokens can be used to cancel ongoing notification tasks.
Constructors¶
| Name | Summary |
|---|---|
| .ctor |
Methods¶
| Name | Summary |
|---|---|
| OnNextAsync | Asynchronously processes the next value in the sequence. |
| OnErrorResumeAsync | Handles the specified error and resumes asynchronous processing, if possible. |
| OnCompletedAsync | Performs asynchronous completion logic in response to the specified result. |
| DisposeAsync | |
| SubscribeAsync | Subscribes the specified asynchronous observer to receive notifications from the observable sequence. |